cb5794491ade6f5fb076201cc79f72a57cae4eed,server/src/test/java/timely/store/iterators/TimeSeriesGroupingIteratorTest.java,TimeSeriesGroupingIteratorTest,testAdditionalTimeSeries,#,165
Before Change
iter.next();
if (i > 54) {
assertTrue(iter.hasTop());
double expected2 = expectedMovingAverage(new double[] { (i - 4) * 2, (i - 3) * 2, (i - 2) * 2,
(i - 1) * 2, i * 2 });
assertEquals(expected2, MetricAdapter.decodeValue(iter.getTopValue().get()), 0.0D);
iter.next();
}
}
assertFalse(iter.hasTop());
After Change
}
}
SortedMapIterator source = new SortedMapIterator(table);
TimeSeriesGroupingIterator iter = new TimeSeriesGroupingIterator();
IteratorSetting settings = new IteratorSetting(100, TimeSeriesGroupingIterator.class);
settings.addOption(TimeSeriesGroupingIterator.FILTER, "0.20,0.20,0.20,0.20,0.20");
iter.init(source, settings.getOptions(), SCAN_IE);
iter.seek(new Range(), EMPTY_COL_FAMS, true);
for (int i = 4; i < 100; i++) {
checkNextResult(iter, new double[] { i - 4, i - 3, i - 2, i - 1, i });
if (i > 54) {
checkNextResult(iter, new double[] { (i - 4) * 2, (i - 3) * 2, (i - 2) * 2, (i - 1) * 2, i * 2 });
}
}
assertFalse(iter.hasTop());